package com.hmdp.config;
import org.springframework.stereotype.Component;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.StreamEntryID;

import javax.annotation.PostConstruct;

/**
 * windows版本的我redis低于5.0，无法使用stream消息队列的相关命令
 * 在此采用spring配置类的方法进行stream队列和组的创建
 * 目前执行不了该程序
 */
//@Component
public class RedisInitializer {

    @PostConstruct
    public void init() {
        // 连接到 Redis 服务器
        Jedis jedis = new Jedis("127.0.0.1", 6379);

        try {
            // 尝试执行 XGROUP CREATE 命令
            jedis.xgroupCreate("stream.orders", "g1", new StreamEntryID("0"), true);
            System.out.println("XGROUP command executed successfully.");
        } catch (Exception e) {
            System.out.println("Error: " + e.getMessage());
        } finally {
            // 关闭连接
            jedis.close();
        }
    }
}